package com.sven.hello;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Processor;
import org.springframework.integration.annotation.ServiceActivator;

/**
 * 消息中转类
 * app2接收app1的消息，转发给app3
 */
// @EnableBinding(Processor.class)
public class TransFormService {

    /*@ServiceActivator(inputChannel = Processor.INPUT,outputChannel = Processor.OUTPUT)
    public Object transform(Object payload){
        System.out.println("消息中转站："+payload);
        return payload;
    }*/
}
